package com.xiaoran.actiiveNIO.topic;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class JmsProduce_topic {
    public static final String ACTIVEMQ_URL="tcp://192.168.171.128:61616";
    public static final String TOPIC_NAMQ="jdbc-topic";
    public static void main(String args[]) throws JMSException {

        //1创建连接工场，，按照给定的url地址，采用默认的用户名和密码
        ActiveMQConnectionFactory activeMQConnectionFactory=new ActiveMQConnectionFactory(ACTIVEMQ_URL);

        //2通过连接工厂获得连接，
        Connection connection = activeMQConnectionFactory.createConnection();

        //3.创建会话session
        Session session= connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        //4.创建目的地
        Topic topic= session.createTopic(TOPIC_NAMQ);

        //5.创建消息生产者,指定目的地
        MessageProducer messageProducer= session.createProducer(topic);

        //指定持久化主题
        messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);

        //connection并启动
        connection.start();

        //6，通过使用消息的生产者发送3条信息到队列；
        for (int i=1;i<=3;i++){
            //7，创建消息
            TextMessage textMessage=session.createTextMessage("TOPIC_NAMQ---------"+i);
            //8.通过生产者发送给你MQ
            messageProducer.send(textMessage);
        }
        messageProducer.close();
        session.close();
        connection.close();
        System.out.println("****TOPIC_NAMQ消息发布到MQ完成");
    }
}

